package com.yanfan.zutai.controller.xunraostrage;

import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONUtil;

import com.yanfan.mqttclient.PubMqttClient;
import com.yanfan.zutai.domain.BDeviceRealData;

import java.util.HashMap;
import java.util.Map;

public class ConsumerXunrao4 implements ConsumerXunrao {
    String xunraoTopic = "/cloud/message/236F6A1734AE4CDCBCA06D0D6C2AF4F2/cmd/set";

    @Override
    public void consumer(PubMqttClient mqttClient, BDeviceRealData bDeviceRealData) {

        // 讯绕topic
        Map xunraoMap = new HashMap();
        xunraoMap.put("ver", "2.0.0");
        xunraoMap.put("pKey", "message");
        xunraoMap.put("sn", "236F6A1734AE4CDCBCA06D0D6C2AF4F2");
        xunraoMap.put("seq", "1012800");
        xunraoMap.put("type", "cmd/set");
        xunraoMap.put("ts", DateUtil.currentSeconds());
        Map xunraoDataMap = new HashMap();
        xunraoDataMap.put("sysid", "1169925172722737152");
        xunraoDataMap.put("dev", bDeviceRealData.getDeviceImei());
        xunraoDataMap.put("m", bDeviceRealData.getParamField());
        xunraoDataMap.put("v", bDeviceRealData.getParamValue());
        xunraoMap.put("data", xunraoDataMap);
        mqttClient.publish(1, false, xunraoTopic, JSONUtil.toJsonStr(xunraoMap));
    }
}
